package online.hxstar.cloud.dead.stream.listenner;

import lombok.extern.slf4j.Slf4j;
import online.hxstar.cloud.dead.stream.bind.HelloBinding;
import org.springframework.cloud.stream.annotation.EnableBinding;
import org.springframework.cloud.stream.annotation.StreamListener;

/**
 * @author xinghu
 * @version 1.0
 * @date 2019/11/12 11:39 上午
 */
@EnableBinding(HelloBinding.class)
@Slf4j
public class HelloListener {


	@StreamListener(target = HelloBinding.GREETING_INPUT)
	public void processHelloChannelGreeting(String message) {
		log.info(message);
	}
}
